package com.gengzp.mq.client.annotations;

import org.springframework.stereotype.Component;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * @ClassName MqMessageListener
 * @Description 消息队列消费者监听注解
 * @Author gengzp
 * @Date 2025/6/9 23:16
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Component
public @interface MqMessageListener {

    /**
     * 监听的主题
     */
    String topic();

    /**
     * 消费者组
     */
    String consumerGroup();

}
